package com.ly.kafka.service;

import org.apache.kafka.clients.admin.TopicDescription;
import org.apache.kafka.common.KafkaFuture;

import java.util.Map;

public interface KafkaService {


    KafkaFuture<Map<String, TopicDescription>> SelectTopicInfo(String topicName);

    /**
     * @describe：修改分区副本个数
     * @author：李勇
     * @date：2023/4/13
     * @param topicName
     * @param number
     * @return：void
     */
    void editTopicPartitionNum(String topicName,Integer number);

}
